// 优化数据库连接方法
var MongoClient = require('mongodb').MongoClient;
var ObjectID = require('mongodb').ObjectID; // 获取 mongodb 的 id

var Config = {
  dbUrl: 'mongodb://localhost:27017/',
  dbName: 'koa'
}

class Db {
  static getInstance () {   /*1、单例  多次实例化实例不共享的问题*/
    if (!Db.instance) {
      Db.instance = new Db();
    }
    return Db.instance;
  }

  constructor() {
    this.dbClient = ''; /*属性 放db对象*/
    this.connect();   /*实例化的时候就连接数据库*/

  }
  connect () {  /*连接数据库*/
    let _that = this;
    return new Promise((resolve, reject) => {
      if (!_that.dbClient) {         /*1、解决数据库多次连接的问题*/
        MongoClient.connect(Config.dbUrl, (err, client) => {
          if (err) {
            reject(err)
          } else {
            _that.dbClient = client.db(Config.dbName);
            resolve(_that.dbClient)
          }
        })
      } else {
        resolve(_that.dbClient);
      }
    })
  }

  find (collectionName, json) {/*数据库查询*/
    return new Promise((resolve, reject) => {
      this.connect().then((db) => {
        var result = db.collection(collectionName).find(json);
        result.toArray(function (err, docs) {
          if (err) {
            reject(err);
            return;
          }
          resolve(docs);
        })
      })
    })
  }
  update (collectionName, json1, json2) {/*数据库更新*/
    return new Promise((resolve, reject) => {
      this.connect().then((db) => {
        //db.user.update({},{$set:{}})
        db.collection(collectionName).updateOne(json1, {
          $set: json2
        }, (err, result) => {
          if (err) {
            reject(err);
          } else {
            resolve(result);
          }
        })
      })
    })
  }
  insert (collectionName, json) {/*数据库添加*/
    return new Promise((resolve, reject) => {
      this.connect().then((db) => {
        db.collection(collectionName).insertOne(json, function (err, result) {
          if (err) {
            reject(err);
          } else {
            resolve(result);
          }
        })
      })
    })
  }
  remove (collectionName, json) {/*数据库删除*/
    return new Promise((resolve, reject) => {
      this.connect().then((db) => {
        db.collection(collectionName).removeOne(json, function (err, result) {
          if (err) {
            reject(err);
          } else {
            resolve(result);
          }
        })
      })
    })
  }

  getObjectId (id) {    /*mongodb里面查询 _id 把字符串转换成对象*/
    return new ObjectID(id);
  }
}
// 使用代理方式 在其他地方就可以使用 new DB() 
const DB = function () {
  let instance
  return function () {
    if (!instance) {
      instance = new Db()
    }
    return instance
  }
}

// module.exports = Db.getInstance();
module.exports = DB;
